package com.wugenqiang.test.main;

import com.wugenqiang.test.readingFromKafka.ReadingFromKafka;

/**
 * @author wugenqiang
 * @Title: Main
 * @ProjectName kafka_flink_opentsdb
 * @Description: mainClass实现读取Kafka调用实现
 * @date 2018/8/29 10:22
 */
public class Main {

    /**
     　　* @Description: mainClass实现读取Kafka调用实现
     　　* @param [args]
     　　* @return void
     　　* @throws
     　　* @author wugenqiang
     　　* @date 2018/8/29 10:23
     　　*/
    public static void main(String[] args) {
        ReadingFromKafka readingFromKafka = new ReadingFromKafka();
        //调用readingFromKafka()实现读取kafka数据
        readingFromKafka.readingFromKafka();
    }
}
